package com.sh.data.engine.domain.datadev.flink.model.domain;

import lombok.Data;

import java.util.Date;
import java.util.List;

/**
 * @author : fuchen
 * @date : 2021/6/16 10:33
 */
@Data
public class FlinkLogRecordDomain {

    private Long id;

    private String taskName;

    private Integer status;

    private Long nodeId;

    private Date startTime;

    private Date endTime;

    private Integer taskType;

    private List<String> kafkaSourceTables;

    private String userName;

    private Integer scheduleType;

    private Long expendTime;

    private Integer Isattention;

    private Integer execType;
}
